package com.qf;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.Pipeline;

public class MainApp {
//    public static void main(String[] args) {
//        //获取连接
//        // 空参默认连接的是本机的6379
//        Jedis jedis = new Jedis("192.168.247.132",6379);
//
//        //执行操作
//        jedis.auth("123456");
//        jedis.hset("jedis:hash","uname","zs");
//
//        System.out.println("================");
//        String uname = jedis.hget("jedis:hash", "uname");
//        System.out.println(uname);
//
//        //释放连接
//        jedis.close();
//    }

//    public static void main(String[] args) {
//        JedisPoolConfig config = new JedisPoolConfig();
//        //初始连接
//        config.setMaxIdle(5);
//        //最大连接
//        config.setMaxTotal(50);
//        //最大等待超时
//        config.setMaxWaitMillis(3000);
//        //创建连接池
//        JedisPool jp = new JedisPool(config,"192.168.247.132",6379);
//
//        //根据连接池获取连接对象
//        Jedis jedis = jp.getResource();
//        jedis.auth("123456");
//
//        //操作
//        String uname = jedis.hget("jedis:hash", "uname");
//        System.out.println(uname);
//
//        //关闭连接（归还连接）
//        jedis.close();
//    }

//    public static void main(String[] args) {
//        Jedis jedis = JedisUtils.getJedis();
//
//        //操作
//        String uname = jedis.hget("jedis:hash", "uname");
//        System.out.println(uname);
//
//        //关闭连接（归还连接）
//        jedis.close();
//    }

    public static void main(String[] args) {
        //向redis中写入1000数据（批量操作）
        Jedis jedis = JedisUtils.getJedis();

        long start = System.currentTimeMillis();

     /*   //传统方式：900ms
        for (int i = 0; i < 1000; i++) {
            jedis.set("key:"+i,"value:"+i);
        }*/

        //管道方式：30ms
        Pipeline pipelined = jedis.pipelined();
        for (int i = 0; i < 1000; i++) {
            pipelined.set("key:"+i,"value:"+i);
        }

        long end = System.currentTimeMillis();

        System.out.println("耗时：" + (end - start));

        jedis.close();
    }
}
